### Name agent, source, channels and sink alias
a1.sources = s1
a1.channels = c1
a1.sinks = k1

a1.sources.s1.type = org.apache.flume.source.kafka.KafkaSource
a1.sources.s1.batchSize = 5000
a1.sources.s1.batchDurationMillis = 2000
a1.sources.s1.kafka.bootstrap.servers = node101:9092
a1.sources.s1.kafka.consumer.group.id = evaluation_group
a1.sources.s1.kafka.consumer.auto.offset.reset = earliest
a1.sources.s1.kafka.topics = host_zzdetail


a1.sinks.k1.type = hdfs
# /home/hdp_idea/rawdata/hism/host/raw_hism_host_zzdetail/20240629
a1.sinks.k1.hdfs.path = hdfs://node101:9090/home/hdp_idea/rawdata/hism/host/raw_hism_host_zzdetail/%Y%m%d
a1.sinks.k1.hdfs.rollSize = 0
a1.sinks.k1.hdfs.rollCount = 0
a1.sinks.k1.hdfs.rollInterval = 3600
a1.sinks.k1.hdfs.threadsPoolSize = 30
a1.sinks.k1.hdfs.fileType=DataStream
a1.sinks.k1.hdfs.writeFormat=Text

a1.channels.c1.type = file
a1.channels.c1.capacity = 100000
a1.channels.c1.transactionCapacity = 10000

### 绑定source、channel和sink
a1.sources.s1.channels = c1
a1.sinks.k1.channel = c1
